//package org.ricks.net.kcp;
//
//import org.ricks.net.AioSession;
//import org.ricks.net.handler.Protocol;
//import proto.common.FProto;
//
//import java.io.IOException;
//import java.nio.ByteBuffer;
//
//public class KcpProtocol implements Protocol<FProto> {
//
//    @Override
//    public FProto decode(ByteBuffer byteBuffer, AioSession aioSession) throws IOException {
//        byte data = byteBuffer.get();
//        int len = byteBuffer.getInt();
//        byte[] bytes = new byte[byteBuffer.remaining()];
//        byteBuffer.get(bytes);
//        FProto fProto = FProto.parseFrom(bytes);
//        return fProto;
//    }
//}
